package rhelper

import (
	"github.com/garyburd/redigo/redis"
	"time"
)

func newPool(server string) *redis.Pool {
	return &redis.Pool{
		MaxIdle:   3,
		MaxActive: 20,
		//IdleTimeout: 240 * time.Second,
		IdleTimeout: 0,
		Dial: func() (redis.Conn, error) {
			c, err := redis.Dial("tcp", server)
			if err != nil {
				return nil, err
			}

			return c, err
		},
		TestOnBorrow: func(c redis.Conn, t time.Time) error {
			_, err := c.Do("PING")
			return err
		},
	}
}

var (
	pool        *redis.Pool
	redisServer = "localhost:6379"
)

const (
	// farm
	FarmHash = "o:f:"

	// gateway
	GatewayHash = "o:g:"

	// controller
	ControllerHash = "o:c:"

	// task
	TaskHash = "o:t:"

	// plan
	PlanHash = "o:p:"

	// account
	AccountHash = "o:a:"

	// message

	MsgHash   = "o:m:"
	MsgURHash = "o:mu:"

	// index counter
	FarmIdHolder = "o:i:fid"
	MsgIdHolder  = "o:i:mid"
	TaskIdHolder = "o:i:tid"
)

func Pool() *redis.Pool {
	return pool
}

func init() {
	pool = newPool(redisServer)
}
